<?php
//include_once '../Controller/Objects/Mensagem.php';
include_once 'Conexao.php';

class MensagemDataBase {
    
    public function inserir(Mensagem $mensagem){
        $conexao = new Conexao();
        $conexao->abrir();
        try {
            $texto=$mensagem->getTexto();            
            $data=$mensagem->getData();            
            $topico=$mensagem->getTopico()->getId();
            $autor=$mensagem->getAutor()->getLogin();
            $sql = "INSERT INTO tb_mensagem (texto,data,tb_topico_id_topico,tb_perfilatleta_login) VALUES ('$texto','$data','$topico','$autor')";
            mysql_query($sql);
            if (mysql_error($conexao->getCon())) {
                throw new Exception ();            
            }
            //echo "entrou no banco";
        } catch (Exception $exc) {
            throw new Exception('Erro ao inserir mensagem.');
        }
        $conexao->fechar();        
    }
    
    public function excluir($id_mensagem){
        $conexao = new Conexao();
        $conexao->abrir();
        try {                     
            $sql = "DELETE FROM tb_mensagem WHERE id_mensagem='$id_mensagem'"; 
            mysql_query($sql);
            if (mysql_error($conexao->getCon())) {
                throw new Exception ();            
            }
        } catch (Exception $exc) {
            throw new Exception('Mensagem não foi encontrada.');
        }
        $conexao->fechar();        
    }
                 
    public function listarMensagens($topico) {
        $conexao=new Conexao();
        $conexao->abrir();
        $array = array();
        try {
            $id = $topico->getId();
            $sql = "SELECT * FROM tb_mensagem WHERE tb_topico_id_topico ='$id'";
            $resultSet = mysql_query($sql);
            if (mysql_error($conexao->getCon())) {
                throw new Exception ();            
            }
            while($line=mysql_fetch_array($resultSet)){
                    $id_mensagem = $line['id_mensagem'];
                    $texto = $line['texto'];
                    $data = $line['data'];                   
                    $id_topico = $line['tb_topico_id_topico'];            
                    $autor_mensagem = $line['tb_perfilatleta_login']; 
                    /*

                    $sql1 = "SELECT * FROM tb_topico WHERE id_topico='$id_topico'";
                    $rs1 = mysql_query($sql1);
                    $line1 = mysql_fetch_array($rs1);
                    $id_topico = $line1['id_topico'];
                    $titulo = $line1['nome'];
                    $data = $line1['data'];
                    $texto = $line1['texto'];
                    $tb_comunidade_id_comunidade = $line1['tb_comunidade_id_comunidade'];                             
                    $autor_topico = $line1['tb_perfilatleta_login'];
                    
                    $sql2 = "SELECT * FROM tb_comunidade WHERE id_comunidade='$tb_comunidade_id_comunidade'";
                    $rs2 = mysql_query($sql2);
                    $line2 = mysql_fetch_array($rs2);
                    $id_comunidade = $line2['id_comunidade'];
                    $nomeComunidade = $line2['nome'];
                    $descricao = $line2['descricao'];
                    $imagem = $line2['imagem'];
                    $tipoImagem = $line2['tipo_imagem'];            
                    $dono = $line2['tb_perfilatleta_login'];
                    
                    $sql3 = "SELECT * FROM tb_perfilatleta WHERE login='$dono'";
                    $rs3 = mysql_query($sql3);
                    $line3 = mysql_fetch_array($rs3);
                    $pA_comunidade = new PerfilAtleta($line3['login'], $line3['senha'], $line3['status'], $line3['codigoValidacao']);
                    
                    $sql4 = "SELECT * FROM tb_perfilatleta WHERE login='$autor_topico'";
                    $rs4 = mysql_query($sql4);
                    $line4 = mysql_fetch_array($rs4);
                    $pA_topico = new PerfilAtleta($line4['login'], $line4['senha'], $line4['status'], $line4['codigoValidacao']);
                    
                     * 
                     */
                    $sql5 = "SELECT * FROM tb_perfilatleta WHERE login='$autor_mensagem'";
                    $rs5 = mysql_query($sql5);
                    if (mysql_error($conexao->getCon())) {
                        throw new Exception ();            
                    }
                    $line5 = mysql_fetch_array($rs5);
                    $pA_mensagem = new PerfilAtleta($line5['login'], $line5['senha'], $line5['status'], $line5['codigoValidacao']);
        
                    //$comunidade = new Comunidade($id_comunidade, $nomeComunidade, $descricao, $imagem, $tipoImagem, $pA_comunidade);                              
                    //$topico=new Topico($id_topico, $titulo, $texto, $pA_topico, $data, $comunidade);                    

                    $mensagem = new Mensagem($id_mensagem, $texto, $pA_mensagem, $data, $topico);                 
                    array_push($array, $mensagem); 
                }//fim do while
                return $array;
        } catch (Exception $exc) {
            throw new Exception('Não foi possivel realizar a consulta.');
        }
            
    }
    
}//fim da classe

?>
